//package cn.iocoder.yudao.module.system.mq.consumer.sms;
//
//import cn.iocoder.yudao.module.system.mq.message.sms.SmsSendMessage;
//import cn.iocoder.yudao.module.system.service.sms.SmsSendService;
//import lombok.extern.slf4j.Slf4j;
//import org.apache.rocketmq.spring.annotation.RocketMQMessageListener;
//import org.apache.rocketmq.spring.core.RocketMQListener;
//import org.springframework.context.event.EventListener;
//import org.springframework.scheduling.annotation.Async;
//import org.springframework.stereotype.Component;
//
//import javax.annotation.Resource;
//
///**
// * 针对 {@link SmsSendMessage} 的消费者
// *
// * @author zzf
// */
//@RocketMQMessageListener( // 重点：添加 @RocketMQMessageListener 注解，声明消费的 topic
//        topic = SmsSendMessage.TOPIC,
//        consumerGroup = SmsSendMessage.TOPIC + "_CONSUMER"
//)
//@Component
//@Slf4j
//public class SmsSendConsumer implements RocketMQListener<SmsSendMessage> {
//
//    @Resource
//    private SmsSendService smsSendService;
//
//    @Override // 重点：实现 onMessage 方法
//    public void onMessage(SmsSendMessage message) {
//        log.info("[onMessage][消息内容({})]", message);
//        smsSendService.doSendSms(message);
//    }
//
//}
